package com.springboot.jeesite.common.queue.redismq;

import com.springboot.jeesite.common.utils.DateUtils;
import org.springframework.stereotype.Service;

/**
 * 消费者
 *
 * @author xxx
 */
@Service
public class RedisConsumer {

    public void receiveMessage(String message) {
        //收到通道的消息之后处理业务逻辑
        //do...
        System.out.println(DateUtils.getDateTime() + ":---- RedisConsumer reserve message:----" + message);
    }
}